package co.edu.uniandes.bi.etl.audi;

import co.edu.uniandes.bi.db.TweetsDAO;
import co.edu.uniandes.bi.etl.Activity;
import co.edu.uniandes.bi.etl.Row;

public class HechosMonitoreo extends Activity{

	private int llavetweet;
	private int llavefecha;
	private int llaveusuario;
	private int llavepais;
	private boolean positivo;
	private boolean neutral;
	private boolean negativo;
	private TweetsDAO tweetsDAO;
	public HechosMonitoreo()
	{
		super();
		tweetsDAO = TweetsDAO.getInstance();
	}

	public void recibirHechos()
	{
		for (int i = 0; i <input.size(); i++) {
			Row r=input.get(i);
			llavetweet=(Integer) r.getField(Constantes.LLAVE_TWEET);
			llavefecha=(Integer) r.getField(Constantes.LLAVE_FECHA);
			llaveusuario=(Integer) r.getField(Constantes.LLAVE_USUARIO);
			llavepais=(Integer) r.getField(Constantes.LLAVE_PAIS);
			positivo=(Boolean) r.getField(Constantes.COL_POSITIVO);
			neutral=(Boolean) r.getField(Constantes.COL_NEUTRAL);
			negativo=(Boolean) r.getField(Constantes.COL_NEGATIVO);
			publicarHecho();
		}
		
	}
	
	public void publicarHecho()
	{
		String sentencia="insert into hechosmonitoreo (llaveevento, llavefecha, llaveredsocial, llaveusuariors, llavepais, positivo, neutral, negativo) " +
				" values (" + llavetweet + " ," + llavefecha+" ,2 ,"+llaveusuario+","+llavepais+","+positivo+","+neutral+","+negativo+")";
		tweetsDAO.ejecutarSQL(sentencia);
	}
	
	public void execute() 
	{
		recibirHechos();
		executeNext();
	}
}